package com.miaow.common;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;

/**
 * @author HWZ
 * @date 2023年12月20日 16:05
 * @description
 */
//@Component
//@EnableBinding(Source.class)
//public class MessageProducer {
//    private final Source source;
//
//    public MessageProducer(Source source) {
//        this.source = source;
//    }
//
//    public void sendMessage(String message) {
//        source.output().send(MessageBuilder.withPayload(message).build());
//    }
//}
